package com.boot2.core.utils;
// package com.jl.utils;
//
// import kafka.utils.VerifiableProperties;
//
// public class ObjectEncoder implements kafka.serializer.Encoder<T> {
// public ObjectEncoder(VerifiableProperties verifiableProperties) {
// }
//
// @Override
// public byte[] toBytes(T t) { // 填写你需要传输的对象
// return SerializeUtil.serialize(t);
// }
// }